package com.ztjy;

import com.ztjy.dao.MySparkSession;
import com.ztjy.demo.JavaRddDemo;
import com.ztjy.model.JsonModel;
import com.ztjy.utils.JsonUtils;
import lombok.extern.log4j.Log4j2;

/**
 * <p>Description: 入口函数</p>
 * <p>
 * <p>Copyright:  2018-2018 北京掌通未来科技有限公司.All rights reserved.</p>
 *
 * @author wangtonggui
 * @date 2018/8/14
 **/
@Log4j2
public class Main {
    public static void main(String[] args) {
        JsonModel jsonModel = new JsonModel();
        jsonModel.setParam1("skdhf");
        log.info(JsonUtils.getJson(jsonModel));
        log.info("main started");

        MySparkSession.init("spark-learning");
//        JavaRddDemo.test();
        JavaRddDemo.testJoin();
    }
}
